package cn.itsource._02workqueue;

import cn.itsource.utils.RabbitMQUtil;
import com.rabbitmq.client.Channel;

/**
 * @Author: CTL
 * @Description: 生产者，一对多
 * @DateTime: 2023年06月13日 18:22
 */

public class Producer {
    /**
     * @Description 消费队列名
     */
    public static final String AIMPLE_QUEUE_NAME = "_02workqueue";
    public static void main(String[] args) throws Exception {
        // 1.获取连接
        Channel channel = RabbitMQUtil.getchannel();
        // 2.准备一个需要投递的消息
        String msg="hello world RabbitMQ!!!";
        // 3.创建一个队列
        channel.queueDeclare(AIMPLE_QUEUE_NAME,true,false,false,null);
        // 4.发送消息
        for (int i = 0; i < 10; i++) {
            channel.basicPublish("",AIMPLE_QUEUE_NAME,null,(msg+i).getBytes());
            System.out.println(msg+i);
        }
        System.out.println("消息投递成功!!!");
    }
}
